package com.interceptors;

import javax.jms.Message;
import javax.jms.MessageListener;

import org.apache.log4j.Logger;

import com.alibaba.fastjson.JSON;

/**
 * 
 * @Title: KafkaConsumerListener
 * @Description:kafka消息中间件，消费端监听，发现、拉取 消息
 * @Author: zhaotf
 * @Since:2017年2月23日 下午4:54:13
 * @Version:1.0
 */
public class ActiveMQConsumerListener implements MessageListener {
	protected final Logger logger = Logger.getLogger(ActiveMQConsumerListener.class);

	/**
	 * 监听器自动执行该方法 消费消息 自动提交offset 执行业务代码 （high level api
	 * 不提供offset管理，不能指定offset进行消费）
	 */
	@Override
	public void onMessage(Message msg) {
		logger.info("ActiveMQConsumer开始消费:" + JSON.toJSONString(msg));
	}

}
